package com.erbao.io.practice;

/**
 * 主线程
 * 不做关于IO 和 业务
 * @author CaoBaoYin
 * @since 2022/10/10 上午8:04
 */
public class MainThread {

    public static void main(String[] args) {
        //1.创建IO thread （一个或多个）

        // SelectorThreadGroup stg = new SelectorThreadGroup(1);
        // 混杂模式，只有一个负责accept，然后每个SelectorThread都会被分配client进行读写
        SelectorThreadGroup boss = new SelectorThreadGroup(3);
        SelectorThreadGroup worker = new SelectorThreadGroup(3);

        /*try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }*/

        //2.监听的server注册到某个selector上
        boss.setWorkerGroup(worker);
        boss.bind(9999);
        boss.bind(8888);
        boss.bind(7777);
        boss.bind(6666);
    }

}
